package com.yunju.xuexin.xuexincrawler.messagequene;

import io.zbus.mq.Message;

import java.io.IOException;

/**
 * Created by 刘治军 on 2017/10/24.
 */
public interface IProducer {

    public Message publish(Message msg) throws IOException, InterruptedException;
}
